package com.atguigu.day02;

import org.apache.flink.util.MathUtils;

/**
 * @description :
 * @autor :lyh
 */
public class Example8 {
    public static void main(String[] args) {
        Integer key = 1;
        // 第一步：获取 key 的 hashcode
        int hashcode = key.hashCode();
        // 第二步：计算 murmurHash
        int murmurHash = MathUtils.murmurHash(hashcode);
        // 默认最大并行度是128
        // reduce 并行度是4
        // 第三步：计算要去的reduce的并行子任务的索引值
        int idx = (murmurHash % 128) * 4 / 128;
        System.out.println(idx);
    }
}
